package com.zeng.sboot.amqp.consumer.config;

import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class AmqpConfig {

    /**
     * 直接注入到容器使用此
     * @return
     */
    @Bean
    public MessageConverter messageConverter() {
        /**
         * 修改消息转换器: 使用 Jackson2JsonMessageConverter 这样存到 rabbitmy 中的消息就不是序列号的内容,而是直观的JSON字符
         */
        return new Jackson2JsonMessageConverter();
    }
}
